
var mysql = require("mysql");
var { createConnection } = mysql;

// var conn = createConnection({
//     host: "localhost",
//     port: 3306,
//     user: "root",
//     password: "root",
//     database: "2213",
// })

// conn.connect();  开启链接
// conn.end();      关闭链接

// 传入一个sql语句返回promise对象
function query(sql) {
    // node连接mysql 选择数据库
    var conn = createConnection({ // 创建新的链接
        host: "localhost",
        port: 3306,
        user: "root",
        password: "root",
        database: "2213",
    })

    return new Promise(function (resolve, reject) {

        conn.query(sql, function (err, result) {
            if (!err) {
                resolve(result)
            } else {
                reject(err);
            }
            conn.end(); // 查询之后关闭链接
        })
    })
}


module.exports = {
    query
}




